package com.hulin.mqtt.activeMQ;

import org.apache.activemq.command.ActiveMQBytesMessage;
import org.apache.activemq.util.ByteSequence;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;


/**
 * @author HULIN
 * @created with: safety-prod-supv
 * @package com.hlkj.web.controller.activeMQ
 * @description:
 * @date 2019/3/22 15:27
 * @modified By:
 * @Copyright © 2018 HAILIANG Info. Tech Ltd. All rights reserved.
 */

@Component
public class ActiveMQReceiver {


/*    @JmsListener(destination = "electric", containerFactory = "myFactory")
    public void receiveElectricMessage(Object email) {

        ActiveMQBytesMessage activeMQBytesMessage = (ActiveMQBytesMessage)email;
        //System.out.println("activeMQBytesMessage = " + activeMQBytesMessage);
        ByteSequence byteSequence = activeMQBytesMessage.getContent();

        System.out.println("ActiveMQ - receive - " + new String(byteSequence.data));
    }*/
}


